google.golang.org/grpc.Server.opts (field)
66 uses
google.golang.org/grpc (current package)
server.go#L74: return srv.opts.creds
server.go#L90: return istats.NewMetricsRecorderList(srv.opts.statsHandlers)
server.go#L129: opts serverOptions
server.go#L697: for i := uint32(0); i < s.opts.numServerWorkers; i++ {
server.go#L714: opts: opts,
server.go#L730: if s.opts.numServerWorkers > 0 {
server.go#L987: rawConn.SetDeadline(time.Now().Add(s.opts.connectionTimeout))
server.go#L1015: MaxStreams: s.opts.maxConcurrentStreams,
server.go#L1016: ConnectionTimeout: s.opts.connectionTimeout,
server.go#L1017: Credentials: s.opts.creds,
server.go#L1018: InTapHandle: s.opts.inTapHandle,
server.go#L1020: KeepaliveParams: s.opts.keepaliveParams,
server.go#L1021: KeepalivePolicy: s.opts.keepalivePolicy,
server.go#L1022: InitialWindowSize: s.opts.initialWindowSize,
server.go#L1023: InitialConnWindowSize: s.opts.initialConnWindowSize,
server.go#L1024: WriteBufferSize: s.opts.writeBufferSize,
server.go#L1025: ReadBufferSize: s.opts.readBufferSize,
server.go#L1026: SharedWriteBuffer: s.opts.sharedWriteBuffer,
server.go#L1028: MaxHeaderListSize: s.opts.maxHeaderListSize,
server.go#L1029: HeaderTableSize: s.opts.headerTableSize,
server.go#L1030: BufferPool: s.opts.bufferPool,
server.go#L1031: StaticWindowSize: s.opts.staticWindowSize,
server.go#L1071: streamQuota := newHandlerQuota(s.opts.maxConcurrentStreams)
server.go#L1081: if s.opts.numServerWorkers > 0 {
server.go#L1124: st, err := transport.NewServerHandlerTransport(w, r, s.statsHandler, s.opts.bufferPool)
server.go#L1195: compData, pf, err := compress(data, cp, comp, s.opts.bufferPool)
server.go#L1214: if payloadLen > s.opts.maxSendMessageSize {
server.go#L1215: return status.Errorf(codes.ResourceExhausted, "grpc: trying to send message larger than max (%d vs. %d)", payloadLen, s.opts.maxSendMessageSize)
server.go#L1228: interceptors := s.opts.chainUnaryInts
server.go#L1229: if s.opts.unaryInt != nil {
server.go#L1230: interceptors = append([]UnaryServerInterceptor{s.opts.unaryInt}, s.opts.chainUnaryInts...)
server.go#L1242: s.opts.unaryInt = chainedInt
server.go#L1321: if s.opts.binaryLogger != nil {
server.go#L1322: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1361: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1362: dc = s.opts.dc
server.go#L1376: if s.opts.cp != nil {
server.go#L1377: cp = s.opts.cp
server.go#L1399: d, err := recvAndDecompress(&parser{r: stream, bufferPool: s.opts.bufferPool}, stream, dc, s.opts.maxReceiveMessageSize, payInfo, decomp, true)
server.go#L1443: reply, appErr := md.Handler(info.serviceImpl, ctx, df, s.opts.unaryInt)
server.go#L1558: interceptors := s.opts.chainStreamInts
server.go#L1559: if s.opts.streamInt != nil {
server.go#L1560: interceptors = append([]StreamServerInterceptor{s.opts.streamInt}, s.opts.chainStreamInts...)
server.go#L1572: s.opts.streamInt = chainedInt
server.go#L1608: p: parser{r: stream, bufferPool: s.opts.bufferPool},
server.go#L1611: maxReceiveMessageSize: s.opts.maxReceiveMessageSize,
server.go#L1612: maxSendMessageSize: s.opts.maxSendMessageSize,
server.go#L1655: if s.opts.binaryLogger != nil {
server.go#L1656: if ml := s.opts.binaryLogger.GetMethodLogger(stream.Method()); ml != nil {
server.go#L1686: if rc := stream.RecvCompress(); s.opts.dc != nil && s.opts.dc.Type() == rc {
server.go#L1687: ss.decompressorV0 = s.opts.dc
server.go#L1701: if s.opts.cp != nil {
server.go#L1702: ss.compressorV0 = s.opts.cp
server.go#L1703: ss.sendCompressorName = s.opts.cp.Type()
server.go#L1728: if s.opts.streamInt == nil {
server.go#L1736: appErr = s.opts.streamInt(server, ss, info, sd.Handler)
server.go#L1867: if unknownDesc := s.opts.unknownStreamDesc; unknownDesc != nil {
server.go#L1980: if s.opts.numServerWorkers > 0 {
server.go#L1988: if graceful || s.opts.waitForHandlers {
server.go#L2030: if s.opts.codec != nil {
server.go#L2031: return s.opts.codec